package com.lyrcsoft.rxjava1x.operators.filter;

import lombok.extern.slf4j.Slf4j;
import rx.Observable;
import rx.functions.Action1;
import rx.schedulers.Schedulers;

import java.util.concurrent.TimeUnit;

/**
 * @author fujc2dev@126.com
 * @date 2024-11-21
 */
@Slf4j
public class test {
    public static void main(String[] args) throws InterruptedException {
        // 定时器执行
        Observable.interval(100, TimeUnit.MILLISECONDS)
                .observeOn(Schedulers.newThread())
                .subscribe(aLong -> {
                    log.info("TAG ---->" + aLong);
                });

        Thread.sleep(Integer.MAX_VALUE);
    }
}
